// Copyright (c) 2020, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

import 'dart:async';

void main() {
  var controller = StreamController<String>();
  controller.stream((s) {
    print(s);
  });
}

extension Extension<T> on Stream<T> {
  StreamSubscription<T> call(Function onData) {
    return listen((d) {
      onData(d);
    });
  }
}
